package cn.zhaoyuening.zamh.looper;

import cn.zhaoyuening.zamh.handler.MsgHandler;
import cn.zhaoyuening.zamh.msg.Msg;
import cn.zhaoyuening.zamh.queue.MsgQueue;

import java.util.List;
import java.util.Map;

/**
 * Created by 赵岳宁 on 2017/6/3.
 * 实现对消息队列的循环
 */
public interface MsgLooper {
    /**
     * 开启循环
     */
    void loop();

    /**
     * 设置要被监控的消息队列
     * @param queue 消息队列
     */
    void setQueue(MsgQueue queue);

    /**
     * @param msgMap 消息map
     */
    void setMsgMap(Map<Integer,List<MsgHandler>> msgMap);
}
